60139e59c6f33f91281d3316d65ef8e788e6d85c,streams-contrib/streams-persist-mongo/src/main/java/org/apache/streams/mongo/MongoPersistReader.java,MongoPersistReader,connectToMongo,#,156

Before Change


        }

        if (!Strings.isNullOrEmpty(config.getUser()) && !Strings.isNullOrEmpty(config.getPassword()))
            client.authenticate(config.getUser(), config.getPassword().toCharArray());

        if (!client.collectionExists(config.getCollection())) {
            client.createCollection(config.getCollection(), null);

After Change



        if (!Strings.isNullOrEmpty(config.getUser()) && !Strings.isNullOrEmpty(config.getPassword())) {
            MongoCredential credential =
                    MongoCredential.createCredential(config.getUser(), config.getDb(), config.getPassword().toCharArray());
            client = new MongoClient(serverAddress, Lists.<MongoCredential>newArrayList(credential));
        } else {
            client = new MongoClient(serverAddress);